package com.heima.article.listener;

import org.apache.kafka.streams.kstream.KStream;
import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;

public interface ArticleProcess {
    //绑定输入主题
    @Input("article_behavior")
    KStream<String,String> input();
    //绑定输出主题
    @Output("article_result")
    KStream<String,String> output();
}
